package day6

import org.apache.spark.rdd.RDD
import org.apache.spark.sql.{DataFrame, Row, SparkSession}

object Test4 {
  def main(args: Array[String]): Unit = {
    val spark= SparkSession.builder().master("local[*]").appName("cheshi1").getOrCreate()
    val df: DataFrame = spark.read.json("file:///D:\\data\\a.json")

    /**
     * row是一个对象，用来存储一行数据
     *底层将DataFrame表中的一行数据转换成一个Row对象
     * 掌握：如何获取row对象中的值
     */
    val rdd: RDD[Row] = df.rdd
    rdd.foreach(row => {
      // 两种获取方式
      println(row.getLong(0) + "\t" + row.getString(1))
      println(row.getAs[String]("name") + "\t" + row.getAs[Long]("age"))
    })

    spark.close()
  }

}
